from sqlalchemy.orm import sessionmaker,scoped_session
from engine import connect
#执行数据库操作需要创建session
def session(conn):
    Session = sessionmaker(bind=conn) #每次操作需要创建session
    session = Session()
    #线程安全，本地线程实现每个线程用同一个session
    session = scoped_session(Session)
    return session

if __name__ == "__main__":
    conn = connect() #创建数据库连接
    session = session(conn) #创建线程
